package com.lesent.kafka.config;

import com.lesent.kafka.Constant.Constant;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.Arrays;

/**
 * @author shengtao
 * @Description: kafka的消费订阅
 * @date 2018/12/19 17:43
 */
@Configuration
@AutoConfigureAfter(KafkaConfig.class)
public class SubConfig {

//    @Bean
//    public ConsumerContainorFactory consumerContainorFactory(KafkaConsumer kafkaConsumer){
//        kafkaConsumer.subscribe(Arrays.asList(Constant.DEFAULT_TOPIC));
//        kafkaConsumer.
//    }

}
